package com.lei.study;

import org.I0Itec.zkclient.ZkClient;
import org.I0Itec.zkclient.serialize.SerializableSerializer;

/**
 * zkClient - 修改
 *
 * @author 伍磊
 */
public class ZkClientWatchTest {

    public static void main(String[] args) throws Exception {
        ZkClient zkClient = new ZkClient("localhost:2181", 10000, 10000, new SerializableSerializer());

        // 修改节点数据
        zkClient.writeData("/zkClient-1", 8);

        // 删除数据节点
        zkClient.delete("/zkClient-1");
    }
}
